All Questions
11 questions
2votes
1answer
258views
Integrating caliban, ZIO and Akka
I created a small sample project using caliban, akka-persistence and ZIO. I'm not really happy with the wiring code: ...
- 100
3votes
1answer
102views
Akka actor to calculate a soccer league rank
I am new to Scala / Akka and this is my first attempt at writing an actor. The task that I am trying to accomplish is: given a sequence of soccer matches, generate a ranking based on the usual rules ...
5votes
0answers
902views
2votes
0answers
183views
GitHub user graph crawler using akka
This code queries the GitHub followers API and stores the graph in a mongodb collection: ...
- 1,439
1vote
1answer
541views
Akka streams: Bidirectional flow that completes the stage when one side is completed
This is meant to be a bidirectional flow BidiFlow that works exactly as BidiFlow.identity, except that it completes the stage as soon as one of the Flows (in1 -> ...
4votes
2answers
2kviews
Limit HTTP request rate for spray/akka-http
I want to limit the request rate in a spray/akka-http route. I'm not an expert with both scala and spray/akka but learning. So I came up with the following custom directive: ...
- 100
3votes
0answers
413views
Finding the most frequent words in Scala using Akka
I'm new to akka and would like to get some feedback on my first attempt. The code takes text from stdin and finds the top 10 most frequently occurring words. Specifically, I would like to know Is ...
4votes
1answer
632views
Return different type of response based on Accept header
I'm a novice to Scala and Akka-Http and am experimenting with Akka-Http for writing rest services. I have to return JSON or protobuf based on the Accept-Header. ...
2votes
1answer
3kviews
Distributing workload using Akka Router with exception handling
I am fairly new to Akka and I am interested in any feedback about the following code. Is this the correct way to go about distributing workload across a number of threads? Do I use the Akka API ...
4votes
0answers
2kviews
Configuring a JMS Component in akka-camel
I'm trying to write a JMS Consumer using Akka-Camel. For now, I'm using FFMQ as a JMS server. I want to listen on the JMS queue myqueue. Creating the JMS ...
3votes
1answer
322views
Is this Scala/Akka idiomatic and correct for Akka 2.1?
I'm wondering if there is anything i'm overlooking in the code below. I've taken the Pi calculation example, simplified it and converted it to Akka 2.1. More specifically, i use the ask pattern to ...
- 131
